package com.choupin.choupin.utils.redis;

import org.springframework.stereotype.Component;
import redis.clients.jedis.Jedis;

import javax.annotation.processing.SupportedAnnotationTypes;
import java.util.Set;

public  class RedisMessageQueue {

     private static final String MESSAGE_QUEUE="lotteryUserQueue";

//    (发布消息)存储消息队列
     public static void  addMessageQueue(String phone,String queueName){
         //         链接redis服务器
         Jedis jedis=new Jedis("localhost",6379);
         //将用户手机号存入消息队列中
         jedis.sadd(queueName,phone);
         System.out.println("消息队列存入成功！");
         //关闭redis数据库
         jedis.close();
     }

//     (订阅消息)获取消息队列的值
      public static Set<String> getMessageQueue(String queueName){
          //         链接redis服务器
          Jedis jedis=new Jedis("localhost",6379);
//          获取当前时间戳
//          Long currentTime=System.currentTimeMillis();
//         获取消息固定时间间隔内的消息队列
           Set<String> message=jedis.smembers(queueName);
                   //关闭redis数据库
                   jedis.close();
                   return message;
      }


//      删除消息队列中的消息（将消费的数据清空）
      public static void deleteMessageQueue(String queueName,String message ){
          // 链接redis服务器
          Jedis jedis=new Jedis("localhost",6379);
//          将消费的数据清空
           jedis.srem(queueName,message);
          //关闭redis数据库
          jedis.close();
      }

//      删除所有消息
    public static void deleteAllMessageQueue(String queueName){
        // 链接redis服务器
        Jedis jedis=new Jedis("localhost",6379);
//          将消费的数据清空
        jedis.del(queueName);
        //关闭redis数据库
        jedis.close();
    }

}
